//package com.trt.usercenter.rocketmq;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.cloud.stream.annotation.StreamListener;
//import org.springframework.messaging.Message;
//import org.springframework.messaging.support.ErrorMessage;
//import org.springframework.stereotype.Service;
//
//@Slf4j
//@Service
//public class MyTestStreamConsumer {
//
//    @StreamListener(MySink.MY_INPUT)
//    public void receive(String messageBody){
//        log.info("自定义接口消费：通过stream收到了消息: messageBoy = {}", messageBody);
//        throw new IllegalArgumentException("抛异常");
//    }
//
//    /**
//     * 全局异常处理
//     * @param message 发生异常的消息
//     */
//    @StreamListener( "errorChannel")
//    public void error(Message<?> message) {
//        ErrorMessage errorMessage = (ErrorMessage) message;
//        log.warn("发生异常, errorMessage = {}", errorMessage);
//    }
//
//}
